package com.gzz.orchid.main.facade.rsocket;

import org.springframework.messaging.handler.annotation.DestinationVariable;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.messaging.rsocket.service.RSocketExchange;
import reactor.core.publisher.Mono;

public interface RSMessageService {
    @RSocketExchange("message/{name}")
    public Mono<String> sendMessage(
            @DestinationVariable("name") String name,
            @Payload Mono<String> content
    );
}
